package com.sbp.message.service;

import com.sbp.message.api.entity.LocalRecordStatus;
import com.sbp.message.entity.ConsumerMessageRecord;

public interface ConsumerMessageRecordService {
	/****
	 * 新增记录
	 * @param record
	 * @return
	 */
	void insert(ConsumerMessageRecord record);
	/****
	 * 查询记录
	 */
	ConsumerMessageRecord selectOne(String messageId, String group);
	/****
	 * 删除记录
	 */
	void delete(String messageId, String group);

	/****
	 * 更新record记录状态
	 */
	int updateStatus(String messageId, String group, LocalRecordStatus status);
}
